package com.canal.starter.event;

import com.alibaba.otter.canal.protocol.CanalEntry;

/**
 * @author chen.qian
 * @date 2018/3/19
 */
@FunctionalInterface
public interface CanalEventListener {
    /**
     * run when event was fired
     *
     * @param eventType
     * @param rowData
     */
    void onEvent(CanalEntry.EventType eventType, CanalEntry.RowData rowData);
}
